package mq

var (
	//交换机类型
	MQ_EX_TYPE_direct  = "direct"
	MQ_EX_TYPE_fanout  = "fanout"
	MQ_EX_TYPE_topic   = "topic"
	MQ_EX_TYPE_headers = "headers"
	MQ_EXCHANG         = "exchang_funAnalyse"
	//公告消息推送
	MQ_QUEUE_BULLETIN         = "queue_bulletin"
	MQ_ROUTING_KEY_BULLETIN_1 = "bulletin_1"

	//好友请求处理
	MQ_QUEUE_CHAT         = "queue_chat"
	MQ_ROUTING_KEY_CHAT_1 = "chat_msg"

	//kafka
	MQ_KAFKA_BULLETI            = "bulletin"
	MQ_KAFKA_BULLETI_GROUPNAME  = "group_bulletin" //groupName
	MQ_KAFKA_CHAT_MSG           = "chatMsg"
	MQ_KAFKA_CHAT_MSG_GROUPNAME = "group_chat_msg"
	MQ_KAFKA_CHAT_MSG_KEY       = "key_chat_msg_1"
)
